# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.providers.apache.hdfs.sensors.web_hdfs import WebHdfsSensor
from jms.time_sensor import time_after_00_15
jms_ods__tab_barscan_difficult_check = WebHdfsSensor(
    pool='unlimited_pool',
    task_id="jms_ods__tab_barscan_difficult_check",
    filepath='/dw/hive/jms_ods.db/external/tab_barscan_difficult_hi/dt={{ execution_date | cst_ds }}-23',
    execution_timeout=timedelta(minutes=30),
    email=['rongguangfan@jtexpress.com','yl_bigdata@yl-scm.com'],
    retries=2,
)
jms_ods__tab_barscan_difficult_check << [time_after_00_15]